package com.cloud.stream.app;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Processor;
import org.springframework.messaging.handler.annotation.SendTo;

@EnableBinding(value = { Processor.class })
public class App1 {

	private static Logger logger = LoggerFactory.getLogger(App1.class);

	@StreamListener(Processor.INPUT)
	@SendTo(Processor.OUTPUT)
	public Object receiveFromINput(Object payload) {
		logger.info("Reveive :" + payload);
		return "From Input Channel Return -" + payload;
	}
}
